package com.yesep.learn.mqtt.client.common.future;

import com.yesep.learn.mqtt.client.common.event.OneTimeEventCallBack;

import io.netty.handler.codec.mqtt.MqttPubAckMessage;

/**
 */
public class PublishFuture extends AbstractFuture<MqttPubAckMessage> implements Future<MqttPubAckMessage>, OneTimeEventCallBack<MqttPubAckMessage> {

	@Override
	public void callback(MqttPubAckMessage msg) {
		setDone(msg);
	}
}
